package it.learn.kafka.consumer91;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.kafka.annotation.KafkaListener;

@SpringBootApplication(scanBasePackages = "it.learn.kafka")
public class Consumer8091App {

    public static void main(String[] args) {
        SpringApplication.run(Consumer8091App.class, args);
    }

    @KafkaListener(topics = "topic1")
    public void listen(String in) {
        System.out.println("wxf-Consumer8091 消费者收到信息：" + in);
    }

}
